package com.ruoyi.gateway.service;

import com.ruoyi.gateway.service.impl.MqttClientManagerImpl;

import java.util.Map;

public interface MqttClientManager {

    void createPlatformClients(String deviceClientId);

    boolean forwardToPlatform(String deviceClientId, String deviceTopic, byte[] payload);

    void destroyPlatformClients(String deviceClientId);

    Map<String, MqttClientManagerImpl.PlatformClientInfo> getPlatformClientsStatus();
}
